package com.enjoyor.soa.traffic.frame.support.kafka.send;

import com.enjoyor.soa.traffic.frame.support.kafka.callback.CallbackFailure;
import com.enjoyor.soa.traffic.frame.support.kafka.callback.CallbackSuccess;
import com.enjoyor.soa.traffic.frame.support.kafka.message.KafkaMessage;

public interface IKafkaSendTool {

    public void send(String topic, KafkaMessage msg);

    public void send(String topic, Integer partition, KafkaMessage msg);

    public void send(String topic, KafkaMessage data, CallbackSuccess callbackSuccess, CallbackFailure callbackFailure);

}
